package org.lxy.core.mq;

import org.apache.rocketmq.client.consumer.listener.MessageListener;

/**
 * 消费者公有方法
 * @author 卢心怡
 */
public interface RocketConsumer {

    void init();

    /**
     * @param topics
     * @param tags
     * @param consumerTitel
     * @param messageListener
     */
    void  registerMessageListener(String topics, String tags, String consumerTitel, MessageListener messageListener);
}
